package com.tencent.iov.cowin.befsale.clue.dao.kafka;

/**
 * kafka topic配置
 * @author zly
 * @version 1.0
 */
public class KafkaConfig {

    /**
     * Mq 同步消息给--会员积分，经纪人
     * 下游服务监听Kafka消息队列Topic
     */
    public static final String customerSyncTopic = "clue_distribution_sync_topic";
    public static final String customerSyncTopic_group_id = "scrm_clue";

    /**
     * sync-clue服务发送kafka,clue服务消费
     */
    public static final String syncToClueTopic="sync_to_clue";
    public static final String syncToClueTopicGroupId="scrm_sync_clue";
    /**
     * sync-clue服务发送kafka,clue服务消费
     */
    public static final String oldDataClue="old_data_clue";
    public static final String oldDataClueGroupId="old_data_clue_groupId";

    /**
     * sync-clue服务发送kafka，CRM的线索跟进记录数据消费
     */
    public static final String oldDataClueTopic = "old_data_clue_record";
    public static final String oldDataClueTopicGroupId = "scrm_old_clue_record";

}